package git.soulbgm.pojo.dto;

/**
 * Kafka消费者组信息
 *
 * @author SoulBGM
 * @date 2024-10-08
 */
public class KcgInfo {

    /**
     * 消费组ID
     */
    private String groupId;

    /**
     * 消费组状态
     */
    private String state;

    /**
     * 主题
     */
    private String topic;

    /**
     * 分区
     */
    private int partition;

    /**
     * 当前偏移量
     */
    private long currentOffset;

    /**
     * 最新偏移量
     */
    private long latestOffset;

    /**
     * 滞后量
     */
    private long lag;

    /**
     * 消费主机
     */
    private String host;

    public KcgInfo() {
    }

    public KcgInfo(String groupId, String state, String topic, int partition, long currentOffset, long latestOffset, long lag, String host) {
        this.groupId = groupId;
        this.state = state;
        this.topic = topic;
        this.partition = partition;
        this.currentOffset = currentOffset;
        this.latestOffset = latestOffset;
        this.lag = lag;
        this.host = host;
    }

    public String getGroupId() {
        return groupId;
    }

    public void setGroupId(String groupId) {
        this.groupId = groupId;
    }

    public String getState() {
        return state;
    }

    public void setState(String state) {
        this.state = state;
    }

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public int getPartition() {
        return partition;
    }

    public void setPartition(int partition) {
        this.partition = partition;
    }

    public long getCurrentOffset() {
        return currentOffset;
    }

    public void setCurrentOffset(long currentOffset) {
        this.currentOffset = currentOffset;
    }

    public long getLatestOffset() {
        return latestOffset;
    }

    public void setLatestOffset(long latestOffset) {
        this.latestOffset = latestOffset;
    }

    public long getLag() {
        return lag;
    }

    public void setLag(long lag) {
        this.lag = lag;
    }

    public String getHost() {
        return host;
    }

    public void setHost(String host) {
        this.host = host;
    }
}
